
from pyspark import SparkConf, SparkContext

# 创建SparkConf
conf = SparkConf().setMaster('local[*]').setAppName('test_spark_app')

sc = SparkContext(conf=conf)

print(sc.version)

# 停止spark
sc.stop()
